3de0a5c94ef273850d417031ed23d816655c138f,code/src/main/java/com/googlecode/cqengine/TransactionalIndexedCollection.java,TransactionalIndexedCollection,retrieve,#Query#QueryOptions#,358
Before Change
public ResultSet<O> retrieve(Query<O> query, QueryOptions queryOptions) {
if (isIsolationLevel(queryOptions, READ_UNCOMMITTED)) {
// Allow the query to read directly from the collection with no filtering overhead...
return new CloseableFilteringResultSet<O>(super.retrieve(query, queryOptions), query, queryOptions) {
@Override
public boolean isValid(O object, QueryOptions queryOptions) {
return true;
After Change
public ResultSet<O> retrieve(Query<O> query, QueryOptions queryOptions) {
if (isIsolationLevel(queryOptions, READ_UNCOMMITTED)) {
// Allow the query to read directly from the collection with no filtering overhead...
return super.retrieve(query, queryOptions);
}
// Otherwise apply READ_COMMITTED isolation...